// mysql存储数据
// 需要安装一个模块 mysql
// 检查npm的安装路径 npm config get registry
//npm config set registry https://registry.npm.taobao.org
var mysql = require("mysql");

/**
 * 数据库连接四要素
 * 1.驱动名称：com.mysql.jdbc.driver
 * 2.连接地址 localhost:3306
 * 3.数据库用户名和密码 root root
 * 4.连接数据库名称 test
 */
let conn = mysql.createConnection({ 
    host:"localhost",
    user:"root",
    password:"root",
    database:"tourism"
})

conn.connect;
console.log(conn);

// let sql = "select * from emp";

let query = function(sql,callFunction){ 
    conn.query(sql,(err,data,filed)=>{ 
        if(err){ 
            console.log("err",err);
        }

        callFunction(data);
        // console.log(data);//每条数据以对象格式展示，这个对象可直接转为json格式
        // console.log(filed);
    });
}


// let sql = "select * from emp where ename=? and epwd=?";
// let arr = ['aaa','12345'];//数组里存放的是传入的参数序列

let arrQuery = function (sql,arr,callFunction) {
    conn.query(sql,arr,(err,data,filed)=>{ 
        if(err){ 
            console.log("err",err);
        }
        callFunction(data);//调用回调函数，将data作为传输参数传输到router
        // console.log(data);//每条数据以对象格式展示，这个对象可直接转为json格式
        // console.log(filed);
    });
}

module.exports.query = query;//没有参数的数据库处理
module.exports.arrQuery = arrQuery;//有参数的数据库处理


// 第三种处理方式  事务处理：难度高，暂时不说


// conn.close();
